/*
 *  message_dispatcher.h
 */

#ifndef MESSAGE_DISPATCHER_H
#define MESSAGE_DISPATCHER_H

#include "message.h"
#include "message_queue.h"
#include "runnable.h"

// Cross reference class forward declaration
class Session;

class MessageDispatcher : public Runnable {
public:
    MessageDispatcher(Session* session);
    ~MessageDispatcher();
    void run();
    void send(Message* msg);
private:
    Session* session;
    MessageQueue q;
};

#endif  //MESSAGE_DISPATCHER_H

//{+}

